bae1186b667836ab407e2c247e5b6a6cc1119f87,src/main/java/io/mycat/migrate/SwitchCommitListener.java,SwitchCommitListener,modifyZkRules,#CuratorTransactionFinal#String#List#,184
Before Change
if("count".equals(count.getString("name"))){
Integer xcount=Integer.parseInt( count.getString("value")) ;
count.put("value",String.valueOf(xcount+newDataNodes.size())) ;
transactionFinal.setData().forPath(rulePath,JSON.toJSONBytes(jsonArray)) ;
}
}
}
After Change
Integer xcount=Integer.parseInt( count.getString("value")) ;
count.put("value",String.valueOf(xcount+newDataNodes.size())) ;
if(transactionFinal==null){
transactionFinal= ZKUtils.getConnection().inTransaction().setData().forPath(rulePath, JSON.toJSONBytes(jsonArray)).and();
} else {
transactionFinal.setData().forPath(rulePath, JSON.toJSONBytes(jsonArray));
}
}
}
}
}
return transactionFinal;
}
private static CuratorTransactionFinal modifyTableConfigRules( CuratorTransactionFinal transactionFinal,String schemal,String table ,List<String> newDataNodes )